e76779b52d20b50318a66d23a326649f0bea0c1f,hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxy.java,CacheProxy,containsKey,#K#,92
Before Change
validateNotNull(key);
final Data k = serializationService.toData(key);
final Operation op = new CacheContainsKeyOperation(getDistributedObjectName(), k);
final InternalCompletableFuture<Boolean> f = getNodeEngine().getOperationService().invokeOnPartition(getServiceName(), op,
getPartitionId(getNodeEngine(), k));
return f.getSafely();
}
After Change
Operation operation = operationProvider.createContainsKeyOperation(k);
OperationService operationService = getNodeEngine().getOperationService();
int partitionId = getPartitionId(getNodeEngine(), k);
InternalCompletableFuture<Boolean> f = operationService.invokeOnPartition(getServiceName(), operation, partitionId);
return f.getSafely();
}